
package com.lee.lossycounting; 
 
import com.alibaba.fastjson.JSON; 
import com.lee.info.LkFlowInfo; 
import org.apache.flink.api.java.functions.KeySelector; 
 
public class LkClassifyKeyByFunction implements KeySelector<LkFlowInfo, String> { 
 
    @Override
    public String getKey(LkFlowInfo lkFlowInfo) throws Exception {
        return JSON.toJSONString(lkFlowInfo.getLkList());
    }
} 
 
 
